package com.longe.listen;

import com.longe.channel.MyProcessor;
import org.springframework.cloud.stream.annotation.EnableBinding;
import org.springframework.cloud.stream.annotation.StreamListener;
import org.springframework.stereotype.Component;

/**
 * 监听接收消息
 *
 * 1.需要配置一个通道的接口
 *    内置获取消息的通道接口 Sink（这里使用自定义的 MyProcessor）
 * 2.绑定通道
 * 3.配置一个监听方法 : 当程序从中间件获取数据之后,执行的业务逻辑方法
 *      需要在监听方法上配置@StreamListener
 */
@Component
@EnableBinding(MyProcessor.class)
public class MessageListener {

	//监听binding中的消息
	@StreamListener(MyProcessor.MY_INPUT)
	public void input(String message) {
		System.err.println("获取到消息: " + message);
	}

}